google.golang.org/grpc.serverStream.decompressorV1 (field)
5 uses
google.golang.org/grpc (current package)
server.go#L1689: ss.decompressorV1 = encoding.GetCompressor(rc)
server.go#L1690: if ss.decompressorV1 == nil {
stream.go#L1642: decompressorV1 encoding.Compressor
stream.go#L1824: if err := recv(&ss.p, ss.codec, ss.s, ss.decompressorV0, m, ss.maxReceiveMessageSize, payInfo, ss.decompressorV1, true); err != nil {
stream.go#L1868: if err := recv(&ss.p, ss.codec, ss.s, ss.decompressorV0, m, ss.maxReceiveMessageSize, nil, ss.decompressorV1, true); err == io.EOF {